process streaming elements using multiple worker instances